package com.recruitment.auth.mq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 用户消息消费者
 */
@Slf4j
@Component
public class UserMessageConsumer {
    
    /**
     * 监听用户注册消息
     * @param message 消息内容
     */
    @RabbitListener(queues = UserMessageProducer.USER_REGISTER_QUEUE)
    public void handleUserRegister(String message) {
        try {
            log.info("收到用户注册消息: {}", message);
            // 处理用户注册后的业务逻辑
            // 例如：发送欢迎邮件、初始化用户资料等
        } catch (Exception e) {
            log.error("处理用户注册消息失败: {}", e.getMessage(), e);
        }
    }
    
    /**
     * 监听用户登录消息
     * @param message 消息内容
     */
    @RabbitListener(queues = UserMessageProducer.USER_LOGIN_QUEUE)
    public void handleUserLogin(String message) {
        try {
            log.info("收到用户登录消息: {}", message);
            // 处理用户登录后的业务逻辑
            // 例如：记录登录日志、更新最后登录时间等
        } catch (Exception e) {
            log.error("处理用户登录消息失败: {}", e.getMessage(), e);
        }
    }
} 